package m1_simple;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class Producer {
    public static void main(String[] args) throws Exception{
        //连接 Rabbitmq服务器
        ConnectionFactory factory = new ConnectionFactory();
        //定义队列
        factory.setHost("192.168.126.129");
        factory.setPort(5672);//可选，5672是默认端口
        factory.setUsername("admin");
        factory.setPassword("admin");

        //创建连接
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        //定义队列，会通知服务器想使用一个"helloworld"队列
        //服务器会找到这个队列，如果不存在，服务器会新建队列
        //5个参数名：
        //                     队列名   是否持久队列 是否排他（独占）队列  是否自动删除  其他参数属性
        channel.queueDeclare("helloworld",false,false,false,null);

        //发送消息
        //4个参数：
        //                   空串（以后介绍）  对列明      其他参数属性          消息数据
        channel.basicPublish("","helloworld",null,"!!!hello world!!!".getBytes());

        System.out.println("队列发送完成");
        channel.close();
        connection.close();
    }
}
